package com.dja.nzw.mq.kafka.config;

import org.apache.kafka.common.serialization.StringSerializer;
import org.springframework.kafka.support.serializer.JsonSerializer;

import java.util.Properties;

/**
 * Created by shuyun on 2017/7/15.
 */
public class KafkaProducerProperties {
    /** 服务器地址信息 */
    private String servers;
    /** key序列化类 */
    private String keyClass = StringSerializer.class.getName();
    /** value序列化类 */
    private String valueClass = JsonSerializer.class.getName();

    /** 其它额外的配置 */
    private Properties extras;
}
